package cn.tedu.csmall.stock.webapi.consume;

import cn.tedu.csmall.stock.webapi.config.RabbitMQConfig;
import org.springframework.amqp.rabbit.annotation.RabbitHandler;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Component;

import java.time.LocalDateTime;

@Component
//去监听RabbitMQ队列
@RabbitListener(queues = {RabbitMQConfig.STOCK_QUEUE})
public class RabbitConsumer {
    //一个类中需要一个方法去接收数据进行处理，需要使用@RabbitHandler
    //一个类中只能描述一个方法
    //需要将队列中的数据转成什么类型进行处理，就在方法参数中指定类型即可
    @RabbitHandler
    public void process(LocalDateTime time){
        System.out.println("接收到数据:"+time);
    }
}
